package com.ds.infrastructure.audit.collector.service;

import com.ds.infrastructure.audit.common.entity.KbaBehaviorWrapper;
import org.apache.kafka.common.serialization.Deserializer;

/**
 * 作用：
 *
 * @author WeiShaoying
 * @date 2020/8/24
 */
public class KbaBehaviorWrapperDecoder implements Deserializer<KbaBehaviorWrapper> {

    @Override
    public KbaBehaviorWrapper deserialize(String s, byte[] data) {
        return KbaBehaviorWrapper.toWrapper(data);
    }
}
